package com.fmdj.snm.dao;

import cn.hutool.core.date.DateField;
import cn.hutool.core.date.DateUtil;
import com.fmdj.snm.entry.MessageEntity;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.stereotype.Repository;

import java.util.Date;

@Repository
public class MessageDao {

    @Autowired
    private MongoTemplate mongoTemplate;

    public String insert(MessageEntity entity) {
        Date sendTime = entity.getSendTime();
        sendTime = DateUtil.offset(sendTime, DateField.HOUR, 8);  //  时区转换 因为存储到mongoDB时，时区是UTC+0 它比中国北京市区少8小时 因此直接加8小时即可
        entity.setSendTime(sendTime);

        entity = mongoTemplate.save(entity); //返回的是新插入的文档的id messageId
        return entity.get_id();
    }
}
